package com.yjd.bi.etl;

import com.yjd.bi.report.service.IDataChangeRecordDisposeService;
import com.yjd.comm.annotation.ServiceRemoteProxy;
import com.yjd.job.BaseJob;
import com.yjd.comm.rpm.RpmServiceKeyEnum;

/**
 * <b>description</b>：将bi库处理完毕以及处理失败的数据移到日志表中 <br>
 * <b>time</b>：2016-4-8下午3:47:51 <br>
 * <b>author</b>： ready likun_557@163.com
 */
public class BiDataChangeToLogJob extends BaseJob {

	@Override
	protected boolean doExecute() throws Exception {
		this.dataChangeRecordDisposeService.moveDisposedToLog();
		return true;
	}

	@Override
	protected String getJobType() {
		return BiDataChangeToLogJob.class.getName();
	}

	/**
	 * 数据变更记录处理，数据迁移
	 */
	@ServiceRemoteProxy(serviceUrlResouceKey = RpmServiceKeyEnum.RPM_BI_SERVICE_KEY)
	private IDataChangeRecordDisposeService dataChangeRecordDisposeService;

}
